google.golang.org/grpc/internal/transport.Stream.wq (field)

7 uses

	google.golang.org/grpc/internal/transport (current package)
		http2_client.go#L473: 	s.wq = newWriteQuota(defaultWriteQuota, s.done)
		http2_client.go#L764: 		wq:         s.wq,
		http2_client.go#L1051: 		if err := s.wq.get(int32(len(hdr) + len(data))); err != nil {
		http2_server.go#L603: 	s.wq = newWriteQuota(defaultWriteQuota, s.ctxDone)
		http2_server.go#L618: 		wq:       s.wq,
		http2_server.go#L1108: 	if err := s.wq.get(int32(len(hdr) + len(data))); err != nil {
		transport.go#L258: 	wq           *writeQuota